package com.ververica.cdc.guass.source.kafka;


import java.io.Serializable;
import static com.ververica.cdc.common.utils.Preconditions.checkNotNull;

/**
 * Kafka连接配置类
 */
public class KafkaConnectionOptions implements Serializable {

    private static final long serialVersionUID = 1L;

    private final String bootstrapServers;
    private final String topic;
    private final String groupId;
    private final String scanStartupMode;



    public KafkaConnectionOptions(
            String bootstrapServers,
            String topic,
            String groupId,
            String scanStartupMode) {
        this.bootstrapServers = checkNotNull(bootstrapServers);
        this.topic = checkNotNull(topic);
        this.groupId = checkNotNull(groupId);
        this.scanStartupMode = scanStartupMode;
    }


    // Getter方法
    public String getBootstrapServers() {
        return bootstrapServers;
    }

    public String getTopic() {
        return topic;
    }

    public String getGroupId() {
        return groupId;
    }

    public String getScanStartupMode() {
        return scanStartupMode;
    }
}
